package org.apache.servicecomb.fence.api.resource;

import jakarta.ws.rs.QueryParam;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;

@RequestMapping(path = "/v1/rocketMsg")
public interface RocketMqMsgService {

    @GetMapping(path = "/getConsumedMsgByMsgId")
    RocketMqMsg getByMsgId(@QueryParam("msgId") String  msgId);

    @GetMapping(path = "/insert")
    int insert(@QueryParam("msgId") String msgId,@QueryParam("topic")  String topic, @QueryParam("msgInfo") String msgInfo);
}
